|
Hi @phatboyg, As a result of my research, I think the following error is caused by RabbitMQ, not MT. I think the main reason for this is from the policies , I have described. Frankly, I described it by reading the documentation below, but I think there is a point I missed somewhere. I have 2 rabbitmq nodes and I want to use it as a cluster. Can I learn your opinion on this issue, this is important for me, I am grateful that you have provided the opportunity to improve my application by answering any questions. 👍
RabbitMQ Documentation : https://www.rabbitmq.com/ha.html#what-is-mirroring
My Policies :
MT-Fault-ExceptionType: | System.TimeoutException
The operation has timed out.
at RabbitMQ.Util.BlockingCell`1.WaitForValue(TimeSpan timeout)at RabbitMQ.Client.Impl.SimpleBlockingRpcContinuation.GetReply(TimeSpan timeout)at RabbitMQ.Client.Impl.ModelBase.ModelRpc(MethodBase method, ContentHeaderBase header, Byte[] body)at RabbitMQ.Client.Framing.Impl.Model._Private_ExchangeDeclare(String exchange, String type, Boolean passive, Boolean durable, Boolean autoDelete, Boolean internal, Boolean nowait, IDictionary`2 arguments)at RabbitMQ.Client.Impl.ModelBase.ExchangeDeclare(String exchange, String type, Boolean durable, Boolean autoDelete, IDictionary`2 arguments)at MassTransit.RabbitMqTransport.Contexts.RabbitMqModelContext.c__DisplayClass16_0.b__0()at MassTransit.Util.ChannelExecutor.c__DisplayClass10_0.g__RunMethod\|0()at MassTransit.Util.ChannelExecutor.c__DisplayClass10_0.b__1()at MassTransit.Util.ChannelExecutor.SynchronousFuture`1.Run()--- End of stack trace from previous location ---at MassTransit.Util.ChannelExecutor.Run[T](Func`1 method, CancellationToken cancellationToken)at MassTransit.RabbitMqTransport.Pipeline.ConfigureTopologyFilter`1.ConfigureTopology(ModelContext context)at MassTransit.RabbitMqTransport.Pipeline.ConfigureTopologyFilter`1.c__DisplayClass3_0.d.MoveNext()--- End of stack trace from previous location ---at GreenPipes.PipeExtensions.OneTimeSetup[T](PipeContext context, Func`2 setupMethod, PayloadFactory`1 payloadFactory)at GreenPipes.PipeExtensions.OneTimeSetup[T](PipeContext context, Func`2 setupMethod, PayloadFactory`1 payloadFactory)at MassTransit.RabbitMqTransport.Pipeline.ConfigureTopologyFilter`1.GreenPipes.IFilter.Send(ModelContext context, IPipe`1 next)at MassTransit.RabbitMqTransport.Transport.RabbitMqSendTransport.SendPipe`1.Send(ModelContext modelContext)at GreenPipes.Agents.PipeContextSupervisor`1.GreenPipes.IPipeContextSource.Send(IPipe`1 pipe, CancellationToken cancellationToken)at GreenPipes.Agents.PipeContextSupervisor`1.GreenPipes.IPipeContextSource.Send(IPipe`1 pipe, CancellationToken cancellationToken)at GreenPipes.Agents.PipeContextSupervisor`1.GreenPipes.IPipeContextSource.Send(IPipe`1 pipe, CancellationToken cancellationToken)at GreenPipes.Internals.Extensions.TaskExtensions.c__DisplayClass4_0.d.MoveNext()--- End of stack trace from previous location ---at MassTransit.Util.PendingTaskCollection.Completed(CancellationToken cancellationToken)at MassTransit.Pipeline.Filters.DeserializeFilter.Send(ReceiveContext context, IPipe`1 next)at GreenPipes.Filters.RescueFilter`2.GreenPipes.IFilter.Send(TContext context, IPipe`1 next)
|